package com.aifund.orderservice.service.impl;

import com.aifund.common.entity.AiUser;
import com.aifund.common.enums.user.UserEnum;
import com.aifund.orderservice.service.UserBindExchangeService;
import com.aifund.orderservice.service.UserService;
import io.grpc.Server;
import io.grpc.ServerBuilder;
import io.grpc.stub.StreamObserver;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;


@Service
public class OrderService {

//
//    //定义端口
//    private final int port = 50051;
//    //服务
//    private Server server;
//
//    @Autowired
//    OrderServiceGrpcApi orderServiceGrpcApi;
//
//    public void OrderService(){
//        try {
//            start();
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//    }
//
//
//
//    //启动服务,并且接受请求
//    public void start() throws IOException {
//        server = ServerBuilder.forPort(port).addService(orderServiceGrpcApi).build().start();
//        System.out.println("服务开始启动-------");
//        Runtime.getRuntime().addShutdownHook(new Thread() {
//            @Override
//            public void run() {
//                System.err.println("------shutting down gRPC server since JVM is shutting down-------");
//                OrderService.this.stop();
//                System.err.println("------server shut down------");
//            }
//        });
//    }
//
//    //stop服务
//    private void stop() {
//        if (server != null) {
//            server.shutdown();
//        }
//    }
//
//    //server阻塞到程序退出
//    public void  blockUntilShutdown() throws InterruptedException {
//        if (server!=null){
//            server.awaitTermination();
//        }
//    }

}
